package com.demo.arch.datapulsedemo.v2_pipeline.core;

/**
 * 步骤执行异常
 * 
 * @author DataPulse Team
 */
public class StepExecutionException extends RuntimeException {

  private final String stepName;

  public StepExecutionException(String stepName, String message) {
    super(String.format("[%s] %s", stepName, message));
    this.stepName = stepName;
  }

  public StepExecutionException(String stepName, String message, Throwable cause) {
    super(String.format("[%s] %s", stepName, message), cause);
    this.stepName = stepName;
  }

  public String getStepName() {
    return stepName;
  }
}
